// package com.example.bootintegration.websocket;
//
// import org.springframework.beans.factory.annotation.Autowired;
// import org.springframework.stereotype.Component;
// import org.springframework.web.socket.server.standard.ServerEndpointExporter;
//
// import jakarta.websocket.CloseReason;
// import jakarta.websocket.EndpointConfig;
// import jakarta.websocket.OnClose;
// import jakarta.websocket.OnError;
// import jakarta.websocket.OnMessage;
// import jakarta.websocket.OnOpen;
// import jakarta.websocket.PongMessage;
// import jakarta.websocket.Session;
// import jakarta.websocket.server.PathParam;
// import jakarta.websocket.server.ServerEndpoint;
// import java.nio.ByteBuffer;
//
// @Component
// @ServerEndpoint("/websocket/{type}")
// public class JavaxWebSocketServerEndpoint {
//
//
//     @Autowired
//     private ServerEndpointExporter serverEndpointExporter;
//
//
//     @OnOpen
//     public void onOpen(Session session, EndpointConfig config,
//                        @PathParam(value = "type") String type) {
//         System.out.println(serverEndpointExporter);
//         //连接建立
//         System.out.println("conne..");
//     }
//
//     @OnClose
//     public void onClose(Session session, CloseReason reason) {
//         //连接关闭
//         System.out.println("close..");
//
//     }
//
//     @OnMessage
//     public void onMessage(Session session, String message) {
//         //接收文本信息
//         System.out.println("msg: " + message);
//         session.getAsyncRemote().sendText("hello client");
//
//     }
//
//     @OnMessage
//     public void onMessage(Session session, PongMessage message) {
//         //接收pong信息
//     }
//
//     @OnMessage
//     public void onMessage(Session session, ByteBuffer message) {
//         //接收二进制信息，也可以用byte[]接收
//     }
//
//     @OnError
//     public void onError(Session session, Throwable e) {
//         //异常处理
//     }
// }